const mysql = require('mysql');
const debug = require('debug')//debug配置文件

function connection() {
   return mysql.createConnection({
     host:'localhost',    //数据库地址
     user: 'root', //用户名
     password:'root', //密码
     database:'film' //数据库名
   })
 }

function query(sql, data) {
   // conn.connect();
   const conn = connection()
   return new Promise((resovle, reject) => {
    debug && console.log('sql语句:' + JSON.stringify(sql))
     try {
       conn.query(sql, data, function (error, results, fields) {
         if (error) {
           reject(error)
           debug && console.log('数据库操作失败:' + JSON.stringify(error))
           return
         }
         else {
           resovle(results)
           debug && console.log('数据库操作成功:' + JSON.stringify(results))
         }
       });
     } catch (e) {
       reject(e)
     }
     finally {
       conn.end()
     }
   })
 }

 module.exports ={
   query
 }


